/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package co.edu.distribuidos.conectividad;

import co.edu.distribuidos.mundo.AdministradorArchivos;
import net.jxta.socket.JxtaSocket;
import java.io.File;

/**
 *
 * @author alvar-go@uniandes.edu.co
 */
public class ThreadAtenderPeticion extends ThreadTemplate{
	
	private AdministradorArchivos administrador;
	
    public ThreadAtenderPeticion(JxtaSocket socket, AdministradorArchivos admin)throws Exception{
        super(socket);
        administrador = admin;
    }

    public void run(){
    	try {
    		 String linea = leerLinea();
    		 if( linea.startsWith(ENVIAR)){
    			 String[] datos = linea.split(SEPARADOR);
    			 File archivo = administrador.darArchivo(datos[1]);
    			 String propietario = "nodo1";//administrador.darPropietario(datos[1]);
    			 System.out.println("Antes de enviar propietario");
    			 System.out.println(archivo.toString());
    			 System.out.println(propietario);
    			 if( archivo != null && propietario != null){
    				 System.out.println("Eviabdo propietario");
    				 enviarLinea(PROPIETARIO + SEPARADOR + propietario); 
    				 System.out.println("Envio propietario");
    				 enviarArchivo(archivo);
    				 leerLinea();
    			 }
    		 }
		} catch (Exception e) {
			e.printStackTrace();
			System.out.println("Error de protocolo: " + e.getMessage());
		}
    }

}
